package com.kafka.study.model;

import lombok.Data;

/**
 * 分区状态类（无状态重启安全）
 */
@Data
public class PartitionState {
    long lastProcessedOffset = -1;
    long firstFutureOffset = -1;
    long watermarkTimestamp = System.currentTimeMillis() - 24 * 3600 * 1000; // 默认24小时前
}
